package com.wiscamp.ninechapters.threeparties.wechat.config;

import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
import cn.binarywang.wx.miniapp.bean.WxMaKefuMessage;
import cn.binarywang.wx.miniapp.bean.WxMaMessage;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import cn.binarywang.wx.miniapp.message.WxMaMessageHandler;
import cn.binarywang.wx.miniapp.message.WxMaMessageRouter;
import cn.binarywang.wx.miniapp.message.WxMaXmlOutMessage;
import com.google.common.collect.Maps;
import jakarta.annotation.PostConstruct;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.common.session.WxSessionManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Configuration
// @EnableAutoConfiguration
@EnableConfigurationProperties(WxMaProperties.class)
public class WxMaConfiguration {
    private static final WxMaMessageHandler logHandler = new WxMaMessageHandler() {
        @Override
        public WxMaXmlOutMessage handle(WxMaMessage wxMessage, Map<String, Object> context, WxMaService service,
                                        WxSessionManager sessionManager) throws WxErrorException {
            System.out.println("收到消息：" + wxMessage.toString());
            service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content("收到信息为：" + wxMessage.toJson())
                    .toUser(wxMessage.getFromUser()).build());
            return null;
        }
    };

    private static final Map<String, WxMaMessageRouter> routers = Maps.newHashMap();

    private static Map<String, WxMaService> maServices = Maps.newHashMap();

    private WxMaProperties properties;

    @Autowired
    public WxMaConfiguration(WxMaProperties properties) {
        this.properties = properties;
    }

    public static WxMaService getMaService(String appid) {
        WxMaService wxService = maServices.get(appid);
        if (wxService == null) {
            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
        }

        return wxService;
    }

    public static WxMaMessageRouter getRouter(String appId) {
        return routers.get(appId);
    }

    @PostConstruct
    public void init() {
        List<WxMaProperties.Config> configs = this.properties.getConfigs();
        if (configs == null) {
            throw new RuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！");
        }

        maServices = configs.stream().map(a -> {
            WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
            config.setAppid(a.getAppid());
            config.setSecret(a.getSecret());
            config.setToken(a.getToken());
            config.setAesKey(a.getAesKey());
            config.setMsgDataFormat(a.getMsgDataFormat());

            WxMaService service = new WxMaServiceImpl();
            service.setWxMaConfig(config);
            routers.put(a.getAppid(), this.newRouter(service));
            return service;
        }).collect(Collectors.toMap(s -> s.getWxMaConfig().getAppid(), a -> a));
    }

    /*
     * private WxMaMessageHandler templateMsgHandler = (wxMessage, context,
     * service, sessionManager) ->
     * service.getMsgService().sendTemplateMsg(WxMaTemplateMessage.builder()
     * .templateId("此处更换为自己的模板id") .formId("自己替换可用的formid")
     * .data(Lists.newArrayList( new WxMaTemplateData("keyword1", "339208499",
     * "#173177"))) .toUser(wxMessage.getFromUser()) .build());
     */

    /*
     * private WxMaMessageHandler logHandler = (wxMessage, context, service,
     * sessionManager) -> { System.out.println("收到消息：" + wxMessage.toString());
     * service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content(
     * "收到信息为：" + wxMessage.toJson()) .toUser(wxMessage.getFromUser()).build()); };
     */

    private WxMaMessageRouter newRouter(WxMaService service) {
        final WxMaMessageRouter router = new WxMaMessageRouter(service);
        // router
        // .rule().handler(logHandler).end();
        // .rule().async(false).content("模板").handler(templateMsgHandler).end()
        // .rule().async(false).content("文本").handler(textHandler).end()
        // .rule().async(false).content("图片").handler(picHandler).end()
        // .rule().async(false).content("二维码").handler(qrcodeHandler).end();
        return router;
    }

    /*
     * private WxMaMessageHandler textHandler = (wxMessage, context, service,
     * sessionManager) ->
     * service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content(
     * "回复文本消息") .toUser(wxMessage.getFromUser()).build());
     *
     */

    /*
     * private WxMaMessageHandler picHandler = (wxMessage, context, service,
     * sessionManager) -> { try { WxMediaUploadResult uploadResult =
     * service.getMediaService() .uploadMedia("image", "png",
     * ClassLoader.getSystemResourceAsStream("tmp.png"));
     * service.getMsgService().sendKefuMsg( WxMaKefuMessage .newImageBuilder()
     * .mediaId(uploadResult.getMediaId()) .toUser(wxMessage.getFromUser())
     * .build()); } catch (WxErrorException e) { e.printStackTrace(); } };
     */

    /*
     * private WxMaMessageHandler qrcodeHandler = (wxMessage, context,
     * service, sessionManager) -> { try { final File file =
     * service.getQrcodeService().createQrcode("123", 430); WxMediaUploadResult
     * uploadResult = service.getMediaService().uploadMedia("image", file);
     * service.getMsgService().sendKefuMsg( WxMaKefuMessage .newImageBuilder()
     * .mediaId(uploadResult.getMediaId()) .toUser(wxMessage.getFromUser())
     * .build()); } catch (WxErrorException e) { e.printStackTrace(); } };
     */
}
